//连接mysql数据库
const mysql = require('mysql');
const db = {
    host: '47.107.128.151', //服务器上为localhost
    user: 'www.nskgc.com',
    password: '123456',
    port: "3306",// 默认使用3306端口号
    database: 'www.nskgc.com'

};

function conMysql(sql) {
    const connection = mysql.createConnection(db);
    connection.connect((err) => {
        if (err) {
            console.log(`mysql连接失败: ${err}!`)
        } else {
            console.log('mysql连接成功!')
        }

    });
    // 返回一个Promise承诺对象
    return new Promise((resolve, reject) => {
        connection.query(sql, (err, result) => {
            if (err) {
                reject(err)
            } else {
                // 此处需要将返回数据转为JSON再转回来,否则原数据不为任何数据类型
                let res = JSON.parse(JSON.stringify(result))
                closeMysql(connection)
                resolve(res)
            }
        });
    })
}


function closeMysql(connection) {
    connection.end((err) => {
        if (err) {
            console.log(`mysql关闭失败: ${err}!`)
        } else {
            console.log('mysql关闭成功!')
        }
    })
}

exports.conMysql = conMysql